package com.fudf;

import org.apache.commons.lang3.StringUtils;
import org.apache.flink.table.functions.ScalarFunction;

/**
 * 自定义函数测试
 */
public class StrUdf extends ScalarFunction{

    public StrUdf() {}

    public String eval(String user) {
        if (StringUtils.isNoneBlank(user)) {
            return "udf" + user;
        }
        return null;
    }
}
